package yxk.task.moka;

import com.alibaba.fastjson.JSONObject;
import kd.bos.context.RequestContext;
import kd.bos.exception.KDException;
import kd.bos.logging.Log;
import kd.bos.logging.LogFactory;
import kd.bos.schedule.executor.AbstractTask;
import kd.sdk.plugin.Plugin;

import java.util.List;
import java.util.Map;

/**
 * 人员同步接口
 */
public class MoKaPersonInfoTask extends AbstractTask implements Plugin {
    private static final Log LOG = LogFactory.getLog(MoKaPersonInfoTask.class);
    @Override
    public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException {
        LOG.info("====人员同步已经入=====");
        MoKaService service=new MoKaService();
        String moKaToKen = service.getMoKaToKen();
        LOG.info("====人员moKaToKen:{}",moKaToKen);
        if(moKaToKen != null) {
            List<List<JSONObject>> usersInfo = service.getUsersInfo(moKaToKen);
            for (List<JSONObject> row : usersInfo) {
                service.setListPerson(row, moKaToKen);
            }
        }
    }
}